org.springframework.web.socket.messaging

Class DefaultSimpUserRegistry

java.lang.Object

org.springframework.web.socket.messaging.DefaultSimpUserRegistry

All Implemented Interfaces:

java.util.EventListener, ApplicationListener<ApplicationEvent>, SmartApplicationListener, Ordered, SimpUserRegistry

public class DefaultSimpUserRegistry
extends java.lang.Object
implements SimpUserRegistry, SmartApplicationListener

A default implementation of SimpUserRegistry that relies on AbstractSubProtocolEvent application context events to keep track of connected users and their subscriptions.

Since:

4.2

Author:

Rossen Stoyanchev

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	DefaultSimpUserRegistry.LocalSimpSession
private static class	DefaultSimpUserRegistry.LocalSimpSubscription
private static class	DefaultSimpUserRegistry.LocalSimpUser

Field Summary

Fields

Modifier and Type	Field and Description
private int	order
private java.lang.Object	sessionLock
private java.util.Map<java.lang.String,DefaultSimpUserRegistry.LocalSimpSession>	sessions
private java.util.Map<java.lang.String,DefaultSimpUserRegistry.LocalSimpUser>	users

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
DefaultSimpUserRegistry()

Method Summary

Modifier and Type	Method and Description
java.util.Set<SimpSubscription>	findSubscriptions(SimpSubscriptionMatcher matcher) Find subscriptions with the given matcher.
int	getOrder() Get the order value of this object.
SimpUser	getUser(java.lang.String userName) Get the user for the given name.
int	getUserCount() Return the count of all connected users.
java.util.Set<SimpUser>	getUsers() Return a snapshot of all connected users.
void	onApplicationEvent(ApplicationEvent event) Handle an application event.
void	setOrder(int order) Specify the order value for this registry.
boolean	supportsEventType(java.lang.Class<? extends ApplicationEvent> eventType) Determine whether this listener actually supports the given event type.
boolean	supportsSourceType(java.lang.Class<?> sourceType) Determine whether this listener actually supports the given source type.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

order

private int order

users

private final java.util.Map<java.lang.String,DefaultSimpUserRegistry.LocalSimpUser> users

sessions

private final java.util.Map<java.lang.String,DefaultSimpUserRegistry.LocalSimpSession> sessions

sessionLock

private final java.lang.Object sessionLock

Constructor Detail

DefaultSimpUserRegistry

public DefaultSimpUserRegistry()

Method Detail

setOrder

public void setOrder(int order)

Specify the order value for this registry.

Default is Ordered.LOWEST_PRECEDENCE.

Since:

5.0.8

getOrder

public int getOrder()

Description copied from interface: Ordered

Get the order value of this object.

Higher values are interpreted as lower priority. As a consequence, the object with the lowest value has the highest priority (somewhat analogous to Servlet load-on-startup values).

Same order values will result in arbitrary sort positions for the affected objects.

Specified by:

getOrder in interface Ordered

Returns:

the order value

See Also:

Ordered.HIGHEST_PRECEDENCE, Ordered.LOWEST_PRECEDENCE

supportsEventType

public boolean supportsEventType(java.lang.Class<? extends ApplicationEvent> eventType)

Description copied from interface: SmartApplicationListener

Determine whether this listener actually supports the given event type.

Specified by:

supportsEventType in interface SmartApplicationListener

onApplicationEvent

public void onApplicationEvent(ApplicationEvent event)

Description copied from interface: ApplicationListener

Handle an application event.

Specified by:

onApplicationEvent in interface ApplicationListener<ApplicationEvent>

Parameters:

event - the event to respond to

supportsSourceType

public boolean supportsSourceType(@Nullable
                                  java.lang.Class<?> sourceType)

Description copied from interface: SmartApplicationListener

Determine whether this listener actually supports the given source type.

Specified by:

supportsSourceType in interface SmartApplicationListener

getUser

@Nullable
public SimpUser getUser(java.lang.String userName)

Description copied from interface: SimpUserRegistry

Get the user for the given name.

Specified by:

getUser in interface SimpUserRegistry

Parameters:

userName - the name of the user to look up

Returns:

the user, or null if not connected

getUsers

public java.util.Set<SimpUser> getUsers()

Description copied from interface: SimpUserRegistry

Return a snapshot of all connected users.

The returned set is a copy and will not reflect further changes.

Specified by:

getUsers in interface SimpUserRegistry

Returns:

the connected users, or an empty set if none

getUserCount

public int getUserCount()

Description copied from interface: SimpUserRegistry

Return the count of all connected users.

Specified by:

getUserCount in interface SimpUserRegistry

Returns:

the number of connected users

findSubscriptions

public java.util.Set<SimpSubscription> findSubscriptions(SimpSubscriptionMatcher matcher)

Description copied from interface: SimpUserRegistry

Find subscriptions with the given matcher.

Specified by:

findSubscriptions in interface SimpUserRegistry

Parameters:

matcher - the matcher to use

Returns:

a set of matching subscriptions, or an empty set if none

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object